Eventbridge を使用してKinesis ストリームにインスタンス状態変更通知イベントを送信してみた。

SUMANGALAS

2022.07.26

この記事は公開されてから1年以上経過しています。情報が古い可能性がありますので、ご注意ください。

概要

この記事では、Eventbridge を使用してKinesis ストリームにインスタンス状態変更通知イベントを送信してみました。ここでは、AmazonEC2インスタンスが開始または停止したときにKinesis ストリームにイベントを送信するEventBridgeルールを作成しました。

作成するリソース：

Kinesis Stream
IAM Role
EventBridge rule
EC2 Instance

やってみた

Kinesis ストリームの作成

次のコマンドを使用してData Streamを作成しておきます。

//Create a Kinesis Stream
aws kinesis create-stream --stream-name demo-stream --shard-count 1 --region us-east-1

[describe-stream]コマンドを実行して、ストリームの詳細を取得します。

////Describe the Data Stream
aws kinesis describe-stream --stream-name demo-stream --region us-east-1

//Output
{
    "StreamDescription": {
        "Shards": [
            {
                "ShardId": "shardId-000000000000",
                "HashKeyRange": {
                    "StartingHashKey": "0",
                    "EndingHashKey": "............."
                },
                "SequenceNumberRange": {
                    "StartingSequenceNumber": "..............."
                }
            }
        ],
        "StreamARN": "arn:aws:kinesis:us-east-1:xxxxxxxxxxxx:stream/demo-stream",
        "StreamName": "demo-stream",
        "StreamStatus": "ACTIVE",
        "RetentionPeriodHours": 24,
        "EnhancedMonitoring": [
            {
                "ShardLevelMetrics": []
            }
        ],
        "EncryptionType": "NONE",
        "KeyId": null,
        "StreamCreationTimestamp": "2022-07-26T12:18:33+09:00"
    }
}

IAMロールの作成

EventBridgeがイベントをKinesisStreamに送信できるようにするIAMロールを作成しておきます。
以下のポリシーを含むjson [policy.json] ファイルを作成しておきます。

{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Effect": "Allow",
            "Action": [
                "kinesis:PutRecord",
                "kinesis:PutRecords"
            ],
            "Resource": [
                "arn:aws:kinesis:us-east-1:xxxxxxxxxxxx:stream/demo-stream"
            ]
        }
    ]
}

次のコマンドを使用して、上記のjsonファイルでIAMポリシーを作成しておきます。

//Create an IAM Policy
aws iam create-policy --policy-name EventBridge-Invoke-Kinesis --policy-document file://policy.json

//Output
{
    "Policy": {
        "PolicyName": "EventBridge-Invoke-Kinesis",
        "PolicyId": ".............",
        "Arn": "arn:aws:iam::xxxxxxxxxx:policy/EventBridge-Invoke-Kinesis",
        "Path": "/",
        "DefaultVersionId": "v1",
        "AttachmentCount": 0,
        "PermissionsBoundaryUsageCount": 0,
        "IsAttachable": true,
        "CreateDate": "2022-07-26T03:27:56+00:00",
        "UpdateDate": "2022-07-26T03:27:56+00:00"
    }
}

次のassumeRoleポリシーを含むjsonファイルを作成しておきます。

{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Effect": "Allow",
            "Principal": {
                "Service": "events.amazonaws.com"
            },
            "Action": "sts:AssumeRole"
        }
    ]
}

上記のポリシーでIAMロールを作成しておきます。

//Create an IAM role
aws iam create-role --role-name "EventBridge-Kinesis-role" --assume-role-policy-document file://assumeRole.json

//Output
{
    "Role": {
        "Path": "/",
        "RoleName": "EventBridge-Kinesis-role",
        "RoleId": "............",
        "Arn": "arn:aws:iam::xxxxxxxxxx:role/EventBridge-Kinesis-role",
        "CreateDate": "2022-07-26T03:28:52+00:00",
        "AssumeRolePolicyDocument": {
            "Version": "2012-10-17",
            "Statement": [
                {
                    "Effect": "Allow",
                    "Principal": {
                        "Service": "events.amazonaws.com"
                    },
                    "Action": "sts:AssumeRole"
                }
            ]
        }
    }
}

上記で作成したIAMポリシーをIAMロールにアタッチしておきます。

aws iam attach-role-policy \
     --role-name EventBridge-Kinesis-role \
     --policy-arn 'arn:aws:iam::xxxxxxxxxxx:policy/EventBridge-Invoke-Kinesis'

EventBridge ルールの作成

EventBridge コンソールのナビゲーションペインで [Rules] を選択しておきます。
[Create rule]をクリックしておきます。
ルール名を入力し、[Rule with an event pattern]としてルールタイプを選択しておきます。

イベントソースとして[AWS events or EventBridge partner events]を選択しておきます。

次の設定でイベントパターンを定義しておきます。
- Event source : AWS services
- AWS service : EC2
- Event type : EC2 Instance State-change Notification
- Specific state(s) : running, stopped
- [Any Instance]を選択しておきます。

ターゲットの詳細を入力しておきます。
- Target types: AWS service
- Target : Kinesis stream
- Stream: 以前に作成したKinesisストリームを選択しておきます。
- Execution role: 前の手順で作成したIAMロールを選択しておきます。

上記の設定で、EventBridgeルールを作成しておきます。

テストする

この設定で EC2インスタンスを作成しておきます。
- AMI : Amazon Linux 2 AMI
- インスタンスタイプ : t2.micro
- サブネット：パブリックサブネット
インスタンスを停止して開始すると、イベントがKinesisストリームに送信されます。AWS CLI を使用してストリームからレコードを取得し、イベントが送信されたことを確認できます。
次のコマンドを実行して、シャードイテレータを取得しておきます。

//Command to get Kinesis shard iterator.
aws kinesis get-shard-iterator --shard-id shardId-000000000 --shard-iterator-type TRIM_HORIZON --stream-name demo-stream --region us-east-1

//Output
{
    "ShardIterator": "AAAAAAAAAAEGY........................=="
}

次のコマンドでシャードイテレータを使用して、イベントレコードを取得しておきます。Kinesis のレコードは Base64 でエンコードされています。

//Get Records.
aws kinesis get-records --shard-iterator AAAAAAAAAAEGY........................== --region us-east-1

//Output
{
    "Records": [
        {
            "SequenceNumber": ".........",
            "ApproximateArrivalTimestamp": "2022-07-26T13:45:24.848000+09:00",
            "Data": "eyJ8ZXJz.........",
            "PartitionKey": "............."
        },
        {
            "SequenceNumber": "...........",
            "ApproximateArrivalTimestamp": "2022-07-26T13:57:22.386000+09:00",
            "Data": "eyJ3ZXJza.............",
            "PartitionKey": "................"
        }
    ],
    "NextShardIterator": "AAAAAAAA..............==",
    "MillisBehindLatest": 0
}

データをデコードして、ストリームに送信されたイベントを確認できます。イベントはJSON形式でストリームに送信されます。
以下のデコードされたデータから、[running, stopped]イベントがストリームに送信されていることを確認できます。

//Record 1
{
     "version":"0",
     "id":"........",
     "detail-type":"EC2 Instance State-change Notification",
     "source":"aws.ec2",
     "account":"xxxxxxxxxxx",
     "time":"2022-07-26T04:45:24Z",
     "region":"us-east-1",
     "resources":["arn:aws:ec2:us-east-1:xxxxxxxxxx:instance/i-000000000000"],
     "detail":{"instance-id":"i-00000000000","state":"running"}
}

//Record 2
{
     "version":"0",
     "id":"..........",
     "detail-type":"EC2 Instance State-change Notification",
     "source":"aws.ec2",
     "account":"xxxxxxxxxxx",
     "time":"2022-07-26T04:57:21Z",
     "region":"us-east-1",
     "resources":["arn:aws:ec2:us-east-1:xxxxxxxxxx:instance/i-0000000000000"],
     "detail":{"instance-id":"i-00000000000","state":"stopped"}
}